package com.qfedu.edu.iotserver.service;

import com.baomidou.mybatisplus.core.metadata.IPage;
import com.qfedu.edu.pojo.ExceptionBusiness;
import com.baomidou.mybatisplus.extension.service.IService;

import java.io.UnsupportedEncodingException;

/**
 * <p>
 *  服务类
 * </p>
 *
 * @author xiaobobo
 * @since 2024-09-13
 */
public interface ExceptionBusinessService extends IService<ExceptionBusiness> {
    /**
     * 异常业务消息的处理
      * @param val
     */
    void handlerExceptionBusinessInfo(String val);

    /**
     * 分页查询数据
     * @param currentPage
     * @param pageSize
     * @return
     */
    IPage<ExceptionBusiness> findAll(Integer currentPage, Integer pageSize);

    /**
     * 业务重试
     * @param id
     * @return
     */
    void retry(String id) throws UnsupportedEncodingException;

    /**
     * 查询消息的重试状态
     * @param mqttId
     * @return
     */
    Integer findQueueMessageRetryStatus(String mqttId);
}
